package com.yl.flink.processor;

import com.yl.entity.MultiDataEntity;
import org.apache.flink.api.common.functions.MapFunction;

public class ConvertStreamTypeFunc implements MapFunction<MultiDataEntity, MultiDataEntity> {

    /**
     * 转换数据流的类型
     */
    @Override
    public MultiDataEntity map(MultiDataEntity multiDataEntity) throws Exception {
        return multiDataEntity;
    }
}
